package com.qx.chat.akka.actor;

import akka.actor.DeadLetter;
import akka.actor.UntypedActor;
/**
 * 处理未响应消息actor（就是没人管的消息）
 * @author cyf
 *
 */
public class DeadLetterListener extends UntypedActor{

	@Override
	public void onReceive(Object message) throws Exception {
		if(message instanceof DeadLetter){
			DeadLetter deadLetter = (DeadLetter)message;
			Object msg = deadLetter.message();
			System.out.println("---------------"+msg+"-----------------");
			//TODO 缓存未到达信息
			
		}
	}

}
